package com.simple.datax.flow.preprocessor;

import java.util.List;

import com.simple.datax.flow.message.BaseEcMessage;
import com.simple.datax.flow.message.EcFlowMessage;

/** 
 * @Title: PreProcessorService.java 
 * @Package com.simple.datax.flow.adapter 
 * @Description: TODO(添加描述) 
 * @author tonney 
 * @date 2013-1-2 下午01:28:05 
 * @version V1.0 
 */
public interface PreProcessorService {
	
	/**
	 * 接收预处理
	 * @param obj
	 * @return
	 */
	public int recvPreProcessor(BaseEcMessage ecmessage,List<BaseEcMessage> ecMessageList);
	
	/**
	 * 发送预处理
	 * @param obj
	 * @return
	 */
	public int sendPreProcessor(EcFlowMessage ecmessage);

}
